package com.boarsoft.message.store;

import com.boarsoft.message.bean.TargetMQ;

/**
 * 使用消息队列持久化器，从消息存储中读取待发送或重试的消息
 * 
 * @author Mac_J
 *
 */
public interface MessageRecover {

	/**
	 * 绑定持久化器
	 * 
	 * @param messageRoller
	 */
	void setRoller(MessageRoller messageRoller);

	/**
	 * 与目标队列绑定
	 * 
	 * @param queue
	 */
	void setQueue(TargetMQ queue);

	/**
	 * 开始数据恢复
	 */
	void start();
}
